package com.itheima.stream.rabbit;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

/**
 * @Class: MessageConsumerListener
 * @Package com.itheima.stream.rabbit
 * @Description:监听、绑定
 * @Company: http://www.itheima.com/
 */
@EnableBinding(MessageConsumer.class)
public class MessageConsumerListener {
    
    @StreamListener(target = "producerChannel")
    public void getMessage(String msg) {
        System.out.println(">>>>>>>>>>>>>>>>>>>>" + msg);
    }
}
